Micron Document
🎖️GitЯра🎖️

Node / meshtastic / Meshtastic-Android / files / core / data / src / commonTest / kotlin / org / meshtastic / core / data / manager / MeshConnectionManagerImplTest.kt

Displaying Raw • Download

core/data/src/commonTest/kotlin/org/meshtastic/core/data/manager/MeshConnectionManagerImplTest.kt e85300531e124df08788c1b765d50af1bf6d516d (e8530053) Text, 16.23 KB

T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787org.meshtastic.core.data.manager

Tff7b72import T7ee787dev.mokkery.MockMode
Tff7b72import T7ee787dev.mokkery.answering.calls
Tff7b72import T7ee787dev.mokkery.answering.returns
Tff7b72import T7ee787dev.mokkery.every
Tff7b72import T7ee787dev.mokkery.everySuspend
Tff7b72import T7ee787dev.mokkery.matcher.any
Tff7b72import T7ee787dev.mokkery.mock
Tff7b72import T7ee787dev.mokkery.verify
Tff7b72import T7ee787kotlinx.coroutines.CoroutineScope
Tff7b72import T7ee787kotlinx.coroutines.flow.MutableStateFlow
Tff7b72import T7ee787kotlinx.coroutines.flow.flowOf
Tff7b72import T7ee787kotlinx.coroutines.test.StandardTestDispatcher
Tff7b72import T7ee787kotlinx.coroutines.test.UnconfinedTestDispatcher
Tff7b72import T7ee787kotlinx.coroutines.test.advanceTimeBy
Tff7b72import T7ee787kotlinx.coroutines.test.advanceUntilIdle
Tff7b72import T7ee787kotlinx.coroutines.test.runTest
Tff7b72import T7ee787org.meshtastic.core.model.ConnectionState
Tff7b72import T7ee787org.meshtastic.core.model.DataPacket
Tff7b72import T7ee787org.meshtastic.core.model.Node
Tff7b72import T7ee787org.meshtastic.core.repository.AppWidgetUpdater
Tff7b72import T7ee787org.meshtastic.core.repository.CommandSender
Tff7b72import T7ee787org.meshtastic.core.repository.HistoryManager
Tff7b72import T7ee787org.meshtastic.core.repository.MeshLocationManager
Tff7b72import T7ee787org.meshtastic.core.repository.MeshServiceNotifications
Tff7b72import T7ee787org.meshtastic.core.repository.MeshWorkerManager
Tff7b72import T7ee787org.meshtastic.core.repository.MqttManager
Tff7b72import T7ee787org.meshtastic.core.repository.NodeManager
Tff7b72import T7ee787org.meshtastic.core.repository.PacketHandler
Tff7b72import T7ee787org.meshtastic.core.repository.PacketRepository
Tff7b72import T7ee787org.meshtastic.core.repository.PlatformAnalytics
Tff7b72import T7ee787org.meshtastic.core.repository.RadioConfigRepository
Tff7b72import T7ee787org.meshtastic.core.repository.RadioInterfaceService
Tff7b72import T7ee787org.meshtastic.core.repository.ServiceBroadcasts
Tff7b72import T7ee787org.meshtastic.core.repository.ServiceRepository
Tff7b72import T7ee787org.meshtastic.core.repository.UiPrefs
Tff7b72import T7ee787org.meshtastic.core.testing.FakeNodeRepository
Tff7b72import T7ee787org.meshtastic.proto.Config
Tff7b72import T7ee787org.meshtastic.proto.LocalConfig
Tff7b72import T7ee787org.meshtastic.proto.LocalModuleConfig
Tff7b72import T7ee787org.meshtastic.proto.ModuleConfig
Tff7b72import T7ee787kotlin.test.AfterTest
Tff7b72import T7ee787kotlin.test.BeforeTest
Tff7b72import T7ee787kotlin.test.Test
Tff7b72import T7ee787kotlin.test.assertEquals

Tf0883e@OptInTb4b4b4(Te6edf3kotlinxTb4b4b4.Te6edf3coroutinesTb4b4b4.Te6edf3ExperimentalCoroutinesApiTff7b72::Te6edf3classTb4b4b4)
Tff7b72class T56d364MeshConnectionManagerImplTest Tb4b4b4{
Tff7b72private Tff7b72val Te6edf3radioInterfaceService Tff7b72= Te6edf3mockTff7b72<Te6edf3RadioInterfaceServiceTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3serviceRepository Tff7b72= Te6edf3mockTff7b72<Te6edf3ServiceRepositoryTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3serviceBroadcasts Tff7b72= Te6edf3mockTff7b72<Te6edf3ServiceBroadcastsTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3serviceNotifications Tff7b72= Te6edf3mockTff7b72<Te6edf3MeshServiceNotificationsTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3uiPrefs Tff7b72= Te6edf3mockTff7b72<Te6edf3UiPrefsTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3packetHandler Tff7b72= Te6edf3mockTff7b72<Te6edf3PacketHandlerTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3nodeRepository Tff7b72= Te6edf3FakeNodeRepositoryTb4b4b4(Tb4b4b4)
Tff7b72private Tff7b72val Te6edf3locationManager Tff7b72= Te6edf3mockTff7b72<Te6edf3MeshLocationManagerTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3mqttManager Tff7b72= Te6edf3mockTff7b72<Te6edf3MqttManagerTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3historyManager Tff7b72= Te6edf3mockTff7b72<Te6edf3HistoryManagerTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3radioConfigRepository Tff7b72= Te6edf3mockTff7b72<Te6edf3RadioConfigRepositoryTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3commandSender Tff7b72= Te6edf3mockTff7b72<Te6edf3CommandSenderTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3nodeManager Tff7b72= Te6edf3mockTff7b72<Te6edf3NodeManagerTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3analytics Tff7b72= Te6edf3mockTff7b72<Te6edf3PlatformAnalyticsTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3packetRepository Tff7b72= Te6edf3mockTff7b72<Te6edf3PacketRepositoryTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3workerManager Tff7b72= Te6edf3mockTff7b72<Te6edf3MeshWorkerManagerTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)
Tff7b72private Tff7b72val Te6edf3appWidgetUpdater Tff7b72= Te6edf3mockTff7b72<Te6edf3AppWidgetUpdaterTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)

Tff7b72private Tff7b72val Te6edf3dataPacket Tff7b72= Te6edf3DataPacketTb4b4b4(Te6edf3id Tff7b72= T79c0ff4T79c0ff5T79c0ff6Tb4b4b4, Te6edf3time Tff7b72= T79c0ff0LTb4b4b4, Te6edf3to Tff7b72= Ta5d6ff"Ta5d6ff0Ta5d6ff"Tb4b4b4, Te6edf3from Tff7b72= Ta5d6ff"Ta5d6ff0Ta5d6ff"Tb4b4b4, Te6edf3bytes Tff7b72= Tff7b72nullTb4b4b4, Te6edf3dataType Tff7b72= T79c0ff0Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3radioConnectionState Tff7b72= Te6edf3MutableStateFlowTff7b72<Te6edf3ConnectionStateTff7b72>Tb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4)
Tff7b72private Tff7b72val Te6edf3connectionStateFlow Tff7b72= Te6edf3MutableStateFlowTff7b72<Te6edf3ConnectionStateTff7b72>Tb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4)
Tff7b72private Tff7b72val Te6edf3localConfigFlow Tff7b72= Te6edf3MutableStateFlowTb4b4b4(Te6edf3LocalConfigTb4b4b4(Tb4b4b4)Tb4b4b4)
Tff7b72private Tff7b72val Te6edf3moduleConfigFlow Tff7b72= Te6edf3MutableStateFlowTb4b4b4(Te6edf3LocalModuleConfigTb4b4b4(Tb4b4b4)Tb4b4b4)

Tff7b72private Tff7b72val Te6edf3testDispatcher Tff7b72= Te6edf3UnconfinedTestDispatcherTb4b4b4(Tb4b4b4)

Tff7b72private Tff7b72lateinit Tff7b72var Te6edf3managerTb4b4b4: Te6edf3MeshConnectionManagerImpl

Tf0883e@BeforeTest
Tff7b72fun Td2a8ffsetUpTb4b4b4(Tb4b4b4) Tb4b4b4{
Te6edf3every Tb4b4b4{ Te6edf3radioInterfaceServiceTb4b4b4.Te6edf3connectionState Tb4b4b4} Te6edf3returns Te6edf3radioConnectionState
Te6edf3every Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3localConfigFlow Tb4b4b4} Te6edf3returns Te6edf3localConfigFlow
Te6edf3every Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3moduleConfigFlow Tb4b4b4} Te6edf3returns Te6edf3moduleConfigFlow
Te6edf3every Tb4b4b4{ Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionState Tb4b4b4} Te6edf3returns Te6edf3connectionStateFlow
Te6edf3every Tb4b4b4{ Te6edf3serviceRepositoryTb4b4b4.Te6edf3setConnectionStateTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3calls
Tb4b4b4{ Te6edf3call Tff7b72-Tff7b72>
Te6edf3connectionStateFlowTb4b4b4.Te6edf3value Tff7b72= Te6edf3callTb4b4b4.Te6edf3argTff7b72<Te6edf3ConnectionStateTff7b72>Tb4b4b4(T79c0ff0Tb4b4b4)
Tb4b4b4}
Te6edf3every Tb4b4b4{ Te6edf3serviceNotificationsTb4b4b4.Te6edf3updateServiceStateNotificationTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3returns Tffa657Unit
Te6edf3every Tb4b4b4{ Te6edf3commandSenderTb4b4b4.Te6edf3sendAdminTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3returns Tffa657Unit
Te6edf3every Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3stopPacketQueueTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3returns Tffa657Unit
Te6edf3every Tb4b4b4{ Te6edf3locationManagerTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3returns Tffa657Unit
Te6edf3every Tb4b4b4{ Te6edf3mqttManagerTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3returns Tffa657Unit
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3emptyMapTff7b72<Tffa657IntTb4b4b4, Te6edf3NodeTff7b72>Tb4b4b4(Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3sendToRadioTb4b4b4(Te6edf3anyTff7b72<Te6edf3orgTb4b4b4.Te6edf3meshtasticTb4b4b4.Te6edf3protoTb4b4b4.Te6edf3ToRadioTff7b72>Tb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3returns Tffa657Unit
Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffcreateManagerTb4b4b4(Te6edf3scopeTb4b4b4: Te6edf3CoroutineScopeTb4b4b4)Tb4b4b4: Te6edf3MeshConnectionManagerImpl Tff7b72= Te6edf3MeshConnectionManagerImplTb4b4b4(
Te6edf3radioInterfaceServiceTb4b4b4,
Te6edf3serviceRepositoryTb4b4b4,
Te6edf3serviceBroadcastsTb4b4b4,
Te6edf3serviceNotificationsTb4b4b4,
Te6edf3uiPrefsTb4b4b4,
Te6edf3packetHandlerTb4b4b4,
Te6edf3nodeRepositoryTb4b4b4,
Te6edf3locationManagerTb4b4b4,
Te6edf3mqttManagerTb4b4b4,
Te6edf3historyManagerTb4b4b4,
Te6edf3radioConfigRepositoryTb4b4b4,
Te6edf3commandSenderTb4b4b4,
Te6edf3nodeManagerTb4b4b4,
Te6edf3analyticsTb4b4b4,
Te6edf3packetRepositoryTb4b4b4,
Te6edf3workerManagerTb4b4b4,
Te6edf3appWidgetUpdaterTb4b4b4,
Te6edf3scopeTb4b4b4,
Tb4b4b4)

Tf0883e@AfterTest Tff7b72fun Td2a8fftearDownTb4b4b4(Tb4b4b4) Tff7b72= Tffa657Unit

Tf0883e@Test
Tff7b72fun Td2a8ff`Connected state triggers broadcast and config start`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3manager Tff7b72= Te6edf3createManagerTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(
Te6edf3ConnectionStateTb4b4b4.Te6edf3ConnectingTb4b4b4,
Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3valueTb4b4b4,
Ta5d6ff"Ta5d6ffState should be Connecting after radio ConnectedTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3serviceBroadcastsTb4b4b4.Te6edf3broadcastConnectionTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`Disconnected state stops services`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3emptyMapTb4b4b4(Tb4b4b4)
Te6edf3manager Tff7b72= Te6edf3createManagerTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
T8b949e// Transition to Connected first so that Disconnected actually does something
Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Disconnected
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(
Te6edf3ConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4,
Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3valueTb4b4b4,
Ta5d6ff"Ta5d6ffState should be Disconnected after radio DisconnectedTa5d6ff"Tb4b4b4,
Tb4b4b4)
Te6edf3verify Tb4b4b4{ Te6edf3packetHandlerTb4b4b4.Te6edf3stopPacketQueueTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3locationManagerTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3mqttManagerTb4b4b4.Te6edf3stopTb4b4b4(Tb4b4b4) Tb4b4b4}
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`DeviceSleep behavior when power saving is off maps to Disconnected`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
T8b949e// Power saving disabled + Role CLIENT
Tff7b72val Te6edf3config Tff7b72=
Te6edf3LocalConfigTb4b4b4(
Te6edf3power Tff7b72= Te6edf3ConfigTb4b4b4.Te6edf3PowerConfigTb4b4b4(Te6edf3is_power_saving Tff7b72= Tff7b72falseTb4b4b4)Tb4b4b4,
Te6edf3device Tff7b72= Te6edf3ConfigTb4b4b4.Te6edf3DeviceConfigTb4b4b4(Te6edf3role Tff7b72= Te6edf3ConfigTb4b4b4.Te6edf3DeviceConfigTb4b4b4.Te6edf3RoleTb4b4b4.Te6edf3CLIENTTb4b4b4)Tb4b4b4,
Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3localConfigFlow Tb4b4b4} Te6edf3returns Te6edf3flowOfTb4b4b4(Te6edf3configTb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3emptyMapTb4b4b4(Tb4b4b4)

Te6edf3manager Tff7b72= Te6edf3createManagerTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleep
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(
Te6edf3ConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4,
Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3valueTb4b4b4,
Ta5d6ff"Ta5d6ffState should be Disconnected when power saving is offTa5d6ff"Tb4b4b4,
Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`DeviceSleep behavior when power saving is on stays in DeviceSleep`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
T8b949e// Power saving enabled
Tff7b72val Te6edf3config Tff7b72= Te6edf3LocalConfigTb4b4b4(Te6edf3power Tff7b72= Te6edf3ConfigTb4b4b4.Te6edf3PowerConfigTb4b4b4(Te6edf3is_power_saving Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3localConfigFlow Tb4b4b4} Te6edf3returns Te6edf3flowOfTb4b4b4(Te6edf3configTb4b4b4)

Te6edf3manager Tff7b72= Te6edf3createManagerTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleep
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(
Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleepTb4b4b4,
Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3valueTb4b4b4,
Ta5d6ff"Ta5d6ffState should stay in DeviceSleep when power saving is onTa5d6ff"Tb4b4b4,
Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`onRadioConfigLoaded enqueues queued packets and sets time`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Te6edf3manager Tff7b72= Te6edf3createManagerTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Tff7b72val Te6edf3packetId Tff7b72= T79c0ff4T79c0ff5T79c0ff6
Te6edf3everySuspend Tb4b4b4{ Te6edf3packetRepositoryTb4b4b4.Te6edf3getQueuedPacketsTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3returns Te6edf3listOfTb4b4b4(Te6edf3dataPacketTb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3workerManagerTb4b4b4.Te6edf3enqueueSendMessageTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3returns Tffa657Unit

Te6edf3managerTb4b4b4.Te6edf3onRadioConfigLoadedTb4b4b4(Tb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3verify Tb4b4b4{ Te6edf3workerManagerTb4b4b4.Te6edf3enqueueSendMessageTb4b4b4(Te6edf3packetIdTb4b4b4) Tb4b4b4}
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`onNodeDbReady starts MQTT and requests history`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3moduleConfig Tff7b72=
Te6edf3LocalModuleConfigTb4b4b4(
Te6edf3mqtt Tff7b72= Te6edf3ModuleConfigTb4b4b4.Te6edf3MQTTConfigTb4b4b4(Te6edf3enabled Tff7b72= Tff7b72trueTb4b4b4, Te6edf3proxy_to_client_enabled Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4,
Te6edf3store_forward Tff7b72= Te6edf3ModuleConfigTb4b4b4.Te6edf3StoreForwardConfigTb4b4b4(Te6edf3enabled Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4,
Tb4b4b4)
Te6edf3moduleConfigFlowTb4b4b4.Te6edf3value Tff7b72= Te6edf3moduleConfig
Te6edf3every Tb4b4b4{ Te6edf3commandSenderTb4b4b4.Te6edf3requestTelemetryTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3returns Tffa657Unit
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNum Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(T79c0ff1T79c0ff2T79c0ff3Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3mqttManagerTb4b4b4.Te6edf3startProxyTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3returns Tffa657Unit
Te6edf3every Tb4b4b4{ Te6edf3historyManagerTb4b4b4.Te6edf3requestHistoryReplayTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3returns Tffa657Unit
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3getMyNodeInfoTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3returns Tff7b72null

Te6edf3manager Tff7b72= Te6edf3createManagerTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3managerTb4b4b4.Te6edf3onNodeDbReadyTb4b4b4(Tb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3verify Tb4b4b4{ Te6edf3mqttManagerTb4b4b4.Te6edf3startProxyTb4b4b4(Tff7b72trueTb4b4b4, Tff7b72trueTb4b4b4) Tb4b4b4}
Te6edf3verify Tb4b4b4{ Te6edf3historyManagerTb4b4b4.Te6edf3requestHistoryReplayTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`DeviceSleep timeout is capped at MAX_SLEEP_TIMEOUT_SECONDS for high ls_secs`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
T8b949e// Router with ls_secs=3600 — previously this created a 3630s timeout.
T8b949e// With the cap, it should be clamped to 300s.
Tff7b72val Te6edf3config Tff7b72=
Te6edf3LocalConfigTb4b4b4(
Te6edf3power Tff7b72= Te6edf3ConfigTb4b4b4.Te6edf3PowerConfigTb4b4b4(Te6edf3is_power_saving Tff7b72= Tff7b72trueTb4b4b4, Te6edf3ls_secs Tff7b72= T79c0ff3T79c0ff6T79c0ff0T79c0ff0Tb4b4b4)Tb4b4b4,
Te6edf3device Tff7b72= Te6edf3ConfigTb4b4b4.Te6edf3DeviceConfigTb4b4b4(Te6edf3role Tff7b72= Te6edf3ConfigTb4b4b4.Te6edf3DeviceConfigTb4b4b4.Te6edf3RoleTb4b4b4.Te6edf3ROUTERTb4b4b4)Tb4b4b4,
Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3localConfigFlow Tb4b4b4} Te6edf3returns Te6edf3flowOfTb4b4b4(Te6edf3configTb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3emptyMapTb4b4b4(Tb4b4b4)

Te6edf3manager Tff7b72= Te6edf3createManagerTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Transition to Connected then DeviceSleep
Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleep
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3assertEqualsTb4b4b4(
Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleepTb4b4b4,
Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3valueTb4b4b4,
Ta5d6ff"Ta5d6ffShould be in DeviceSleep initiallyTa5d6ff"Tb4b4b4,
Tb4b4b4)

T8b949e// Advance 300 seconds (the cap) + 1 second to trigger the timeout.
Te6edf3advanceTimeByTb4b4b4(T79c0ff3T79c0ff0T79c0ff1Te6edf3_000LTb4b4b4)

Te6edf3assertEqualsTb4b4b4(
Te6edf3ConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4,
Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3valueTb4b4b4,
Ta5d6ff"Ta5d6ffShould transition to Disconnected after capped timeout (300s), not the raw 3630sTa5d6ff"Tb4b4b4,
Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`rapid state transitions are serialized by connectionMutex`Tb4b4b4(Tb4b4b4) Tff7b72= Te6edf3runTestTb4b4b4(Te6edf3testDispatcherTb4b4b4) Tb4b4b4{
T8b949e// Power saving enabled so DeviceSleep is preserved (not mapped to Disconnected)
Tff7b72val Te6edf3config Tff7b72= Te6edf3LocalConfigTb4b4b4(Te6edf3power Tff7b72= Te6edf3ConfigTb4b4b4.Te6edf3PowerConfigTb4b4b4(Te6edf3is_power_saving Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3localConfigFlow Tb4b4b4} Te6edf3returns Te6edf3flowOfTb4b4b4(Te6edf3configTb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3emptyMapTb4b4b4(Tb4b4b4)

T8b949e// Record every state transition so we can verify ordering
Tff7b72val Te6edf3observed Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3ConnectionStateTff7b72>Tb4b4b4(Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3serviceRepositoryTb4b4b4.Te6edf3setConnectionStateTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3calls
Tb4b4b4{ Te6edf3call Tff7b72-Tff7b72>
Tff7b72val Te6edf3state Tff7b72= Te6edf3callTb4b4b4.Te6edf3argTff7b72<Te6edf3ConnectionStateTff7b72>Tb4b4b4(T79c0ff0Tb4b4b4)
Te6edf3observedTb4b4b4.Te6edf3addTb4b4b4(Te6edf3stateTb4b4b4)
Te6edf3connectionStateFlowTb4b4b4.Te6edf3value Tff7b72= Te6edf3state
Tb4b4b4}

Te6edf3manager Tff7b72= Te6edf3createManagerTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Rapid-fire: Connected -> DeviceSleep -> Disconnected without yielding between them.
T8b949e// Without the Mutex, the intermediate DeviceSleep could be missed or applied out of order.
Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected
Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleep
Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Disconnected
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Verify final state
Te6edf3assertEqualsTb4b4b4(
Te6edf3ConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4,
Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3valueTb4b4b4,
Ta5d6ff"Ta5d6ffFinal state should be Disconnected after rapid transitionsTa5d6ff"Tb4b4b4,
Tb4b4b4)

T8b949e// Verify that all intermediate states were observed in correct order.
T8b949e// Connected triggers handleConnected() which sets Connecting (handshake start),
T8b949e// then DeviceSleep, then Disconnected.
Te6edf3assertEqualsTb4b4b4(
Te6edf3listOfTb4b4b4(Te6edf3ConnectionStateTb4b4b4.Te6edf3ConnectingTb4b4b4, Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleepTb4b4b4, Te6edf3ConnectionStateTb4b4b4.Te6edf3DisconnectedTb4b4b4)Tb4b4b4,
Te6edf3observedTb4b4b4,
Ta5d6ff"Ta5d6ffState transitions should be serialized in order: Connecting -> DeviceSleep -> DisconnectedTa5d6ff"Tb4b4b4,
Tb4b4b4)
Tb4b4b4}

Tf0883e@Test
Tff7b72fun Td2a8ff`concurrent sleep-timeout and radio state change are serialized`Tb4b4b4(Tb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3standardDispatcher Tff7b72= Te6edf3StandardTestDispatcherTb4b4b4(Tb4b4b4)
Te6edf3runTestTb4b4b4(Te6edf3standardDispatcherTb4b4b4) Tb4b4b4{
T8b949e// Power saving enabled with a short ls_secs so the sleep timeout fires quickly
Tff7b72val Te6edf3config Tff7b72= Te6edf3LocalConfigTb4b4b4(Te6edf3power Tff7b72= Te6edf3ConfigTb4b4b4.Te6edf3PowerConfigTb4b4b4(Te6edf3is_power_saving Tff7b72= Tff7b72trueTb4b4b4, Te6edf3ls_secs Tff7b72= T79c0ff1Tb4b4b4)Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3radioConfigRepositoryTb4b4b4.Te6edf3localConfigFlow Tb4b4b4} Te6edf3returns Te6edf3flowOfTb4b4b4(Te6edf3configTb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3emptyMapTb4b4b4(Tb4b4b4)

Tff7b72val Te6edf3observed Tff7b72= Te6edf3mutableListOfTff7b72<Te6edf3ConnectionStateTff7b72>Tb4b4b4(Tb4b4b4)
Te6edf3every Tb4b4b4{ Te6edf3serviceRepositoryTb4b4b4.Te6edf3setConnectionStateTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4} Te6edf3calls
Tb4b4b4{ Te6edf3call Tff7b72-Tff7b72>
Tff7b72val Te6edf3state Tff7b72= Te6edf3callTb4b4b4.Te6edf3argTff7b72<Te6edf3ConnectionStateTff7b72>Tb4b4b4(T79c0ff0Tb4b4b4)
Te6edf3observedTb4b4b4.Te6edf3addTb4b4b4(Te6edf3stateTb4b4b4)
Te6edf3connectionStateFlowTb4b4b4.Te6edf3value Tff7b72= Te6edf3state
Tb4b4b4}

Te6edf3manager Tff7b72= Te6edf3createManagerTb4b4b4(Te6edf3backgroundScopeTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// Transition to Connected -> DeviceSleep to start the sleep timer
Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)
Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3DeviceSleep
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3observedTb4b4b4.Te6edf3clearTb4b4b4(Tb4b4b4)

T8b949e// Before the sleep timeout fires, emit Connected from the radio (simulating device
T8b949e// waking up). Then let the timeout fire. The mutex ensures they don't race.
Te6edf3radioConnectionStateTb4b4b4.Te6edf3value Tff7b72= Te6edf3ConnectionStateTb4b4b4.Te6edf3Connected
T8b949e// Advance past the sleep timeout (ls_secs=1 + 30s base = 31s)
Te6edf3advanceTimeByTb4b4b4(T79c0ff3T79c0ff2Te6edf3_000LTb4b4b4)
Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

T8b949e// The Connected transition should have cancelled the sleep timeout, so we should
T8b949e// end up in Connecting (from handleConnected), NOT Disconnected (from timeout).
Te6edf3assertEqualsTb4b4b4(
Te6edf3ConnectionStateTb4b4b4.Te6edf3ConnectingTb4b4b4,
Te6edf3serviceRepositoryTb4b4b4.Te6edf3connectionStateTb4b4b4.Te6edf3valueTb4b4b4,
Ta5d6ff"Ta5d6ffConnected should cancel the sleep timeout; final state should be ConnectingTa5d6ff"Tb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tb4b4b4}

Served by rngit 1.5.0 - Generated in 0.19s